package com.qupeng.demo.kafka.kafkaspringbootproducer.admin.model;

import lombok.Data;
import org.apache.kafka.common.ConsumerGroupState;

import java.util.Optional;

@Data
public class ConsumerGroupOffsets {
    private String consumerGroupName;
    private String topicName;
    private int partitionNumber;
    private long committedOffset;
    private long latestOffset;

    public ConsumerGroupOffsets(String consumerGroupName, String topicName, int partitionNumber, long committedOffset, long latestOffset) {
        this.consumerGroupName = consumerGroupName;
        this.topicName = topicName;
        this.partitionNumber = partitionNumber;
        this.committedOffset = committedOffset;
        this.latestOffset = latestOffset;
    }
}
